a0786f0d4eadfb2c84805915ca98b11a4c117429,src/main/java/water/exec/ASTRApply.java,RemoteExec,compute2,#,424

Before Change


      System.out.println("ddply on group "+Arrays.toString(_ds)+" rows="+_fr.numRows()+", env="+_env+", op="+_op);
      
      // Clone a private copy of the environment for local execution
      _env = _env.capture(true);

      _env.push(_op);
      _env.push(_fr);

After Change


    @Override public void compute2() {
      Env shared_env = UKV.get(_envkey);
      // Clone a private copy of the environment for local execution
      Env env = shared_env.capture(true);
      ASTOp op = env.fcn(-1);

      System.out.println("ddply on group "+Arrays.toString(_ds)+" rows="+_fr.numRows()+", env="+env+", op="+op);